home *** CD-ROM | disk | FTP | other *** search
/ PC Plus SuperCD (UK) 1998 August / PC Plus SuperCD 50a Issue 142 (CD142a) (August 1998).iso / trial / demon / TURNPIKE.1 / CLASSES.ZIP / sun / AUDIO / AudioDevice.class (.txt) < prev    next >
Encoding:
Java Class File  |  1997-04-14  |  7.2 KB  |  314 lines
  1. package sun.audio;
  2.  
  3. import java.io.IOException;
  4. import java.io.InputStream;
  5. import java.util.Enumeration;
  6. import java.util.Vector;
  7.  
  8. public class AudioDevice {
  9.    private Vector streams;
  10.    private byte[] ulaw;
  11.    private int[] linear;
  12.    private int dev;
  13.    private static final int MSCLICK = 50;
  14.    private static final int MSMARGIN = 16;
  15.    private static final int BYTES_PER_SAMPLE = 1;
  16.    private static final int SAMPLE_RATE = 8000;
  17.    private static final int STATUS_PLAYING = 1;
  18.    private static final int STATUS_READING = 2;
  19.    private static final int ULAW_BIAS = 132;
  20.    private static final int ULAW_CLIP = 32635;
  21.    private static final int[] ULAW_TAB = new int[]{-32124, -31100, -30076, -29052, -28028, -27004, -25980, -24956, -23932, -22908, -21884, -20860, -19836, -18812, -17788, -16764, -15996, -15484, -14972, -14460, -13948, -13436, -12924, -12412, -11900, -11388, -10876, -10364, -9852, -9340, -8828, -8316, -7932, -7676, -7420, -7164, -6908, -6652, -6396, -6140, -5884, -5628, -5372, -5116, -4860, -4604, -4348, -4092, -3900, -3772, -3644, -3516, -3388, -3260, -3132, -3004, -2876, -2748, -2620, -2492, -2364, -2236, -2108, -1980, -1884, -1820, -1756, -1692, -1628, -1564, -1500, -1436, -1372, -1308, -1244, -1180, -1116, -1052, -988, -924, -876, -844, -812, -780, -748, -716, -684, -652, -620, -588, -556, -524, -492, -460, -428, -396, -372, -356, -340, -324, -308, -292, -276, -260, -244, -228, -212, -196, -180, -164, -148, -132, -120, -112, -104, -96, -88, -80, -72, -64, -56, -48, -40, -32, -24, -16, -8, 0, 32124, 31100, 30076, 29052, 28028, 27004, 25980, 24956, 23932, 22908, 21884, 20860, 19836, 18812, 17788, 16764, 15996, 15484, 14972, 14460, 13948, 13436, 12924, 12412, 11900, 11388, 10876, 10364, 9852, 9340, 8828, 8316, 7932, 7676, 7420, 7164, 6908, 6652, 6396, 6140, 5884, 5628, 5372, 5116, 4860, 4604, 4348, 4092, 3900, 3772, 3644, 3516, 3388, 3260, 3132, 3004, 2876, 2748, 2620, 2492, 2364, 2236, 2108, 1980, 1884, 1820, 1756, 1692, 1628, 1564, 1500, 1436, 1372, 1308, 1244, 1180, 1116, 1052, 988, 924, 876, 844, 812, 780, 748, 716, 684, 652, 620, 588, 556, 524, 492, 460, 428, 396, 372, 356, 340, 324, 308, 292, 276, 260, 244, 228, 212, 196, 180, 164, 148, 132, 120, 112, 104, 96, 88, 80, 72, 64, 56, 48, 40, 32, 24, 16, 8, 0};
  22.    private static final int[] ULAW_LUT = new int[]{0, 0, 1, 1, 2, 2, 2, 2, 3, 3, 3, 3, 3, 3, 3, 3, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7};
  23.    public static final AudioDevice device = new AudioDevice();
  24.  
  25.    private native int audioOpen();
  26.  
  27.    private native void audioClose();
  28.  
  29.    private synchronized native void audioWrite(byte[] var1, int var2);
  30.  
  31.    private native int status();
  32.  
  33.    private native void flush();
  34.  
  35.    private native int getBufferDuration();
  36.  
  37.    private AudioDevice() {
  38.       try {
  39.          System.out.println("Creating audio device.");
  40.          Runtime.currentRuntime.loadLibrary("mmedia");
  41.       } catch (UnsatisfiedLinkError var1) {
  42.          System.out.println("could not find/load the mmedia library");
  43.       }
  44.  
  45.       this.streams = new Vector();
  46.       this.ulaw = new byte[400];
  47.       this.linear = new int[400];
  48.    }
  49.  
  50.    public synchronized void openChannel(InputStream var1) {
  51.       this.streams.insertElementAt(var1, 0);
  52.       this.notify();
  53.    }
  54.  
  55.    public synchronized void closeChannel(InputStream var1) {
  56.       if (this.streams.removeElement(var1)) {
  57.          Vector var2 = this.streams;
  58.          if (var2.elementCount == 0) {
  59.             this.audioClose();
  60.          }
  61.  
  62.          try {
  63.             var1.close();
  64.          } catch (IOException var3) {
  65.          }
  66.       }
  67.    }
  68.  
  69.    public synchronized void open() {
  70.       int var1 = 1;
  71.  
  72.       while(this.dev == 0) {
  73.          this.dev = this.audioOpen();
  74.          if (this.dev < 0) {
  75.             System.out.println("no audio device");
  76.             return;
  77.          }
  78.  
  79.          if (this.dev == 0) {
  80.             System.out.println("audio device busy (attempt " + var1 + " out of " + 5 + ")");
  81.             Vector var2 = this.streams;
  82.             if (var2.elementCount != 0) {
  83.                ++var1;
  84.                if (var1 <= 5) {
  85.                   try {
  86.                      this.wait(3000L);
  87.                      System.out.println("waiting 3 seconds?");
  88.                      continue;
  89.                   } catch (InterruptedException var3) {
  90.                      this.closeStreams();
  91.                      return;
  92.                   }
  93.                }
  94.             }
  95.  
  96.             this.closeStreams();
  97.             return;
  98.          }
  99.       }
  100.  
  101.    }
  102.  
  103.    public synchronized void close() {
  104.       if (this.dev != 0) {
  105.          this.audioClose();
  106.          this.dev = 0;
  107.       }
  108.  
  109.       this.closeStreams();
  110.    }
  111.  
  112.    private synchronized void mix() {
  113.       int var1 = this.ulaw.length;
  114.       byte[] var2 = this.ulaw;
  115.       Vector var3 = this.streams;
  116.       switch (var3.elementCount) {
  117.          case 0:
  118.             for(int var20 = var1; var20-- > 0; var2[var20] = 127) {
  119.             }
  120.  
  121.             return;
  122.          case 1:
  123.             InputStream var19 = (InputStream)this.streams.elementAt(0);
  124.             int var4 = 0;
  125.  
  126.             try {
  127.                var4 = var19.read(var2, 0, var1);
  128.             } catch (IOException var14) {
  129.                var4 = -1;
  130.             }
  131.  
  132.             if (var4 <= 0) {
  133.                this.streams.removeElementAt(0);
  134.                var4 = 0;
  135.  
  136.                try {
  137.                   var19.close();
  138.                } catch (IOException var13) {
  139.                }
  140.             }
  141.  
  142.             while(var4 < var1) {
  143.                var2[var4] = 127;
  144.                ++var4;
  145.             }
  146.  
  147.             return;
  148.          default:
  149.             int[] var21 = ULAW_TAB;
  150.             int[] var23 = this.linear;
  151.             Vector var5 = this.streams;
  152.             int var24 = var5.elementCount - 1;
  153.             InputStream var6 = (InputStream)this.streams.elementAt(var24);
  154.             int var7 = 0;
  155.  
  156.             try {
  157.                var7 = var6.read(var2, 0, var1);
  158.             } catch (IOException var18) {
  159.                var7 = -1;
  160.             }
  161.  
  162.             if (var7 <= 0) {
  163.                this.streams.removeElementAt(var24);
  164.                var7 = 0;
  165.  
  166.                try {
  167.                   var6.close();
  168.                } catch (IOException var17) {
  169.                }
  170.             }
  171.  
  172.             for(int var8 = 0; var8 < var7; ++var8) {
  173.                var23[var8] = var21[var2[var8] & 255];
  174.             }
  175.  
  176.             while(var7 < var1) {
  177.                var23[var7] = 0;
  178.                ++var7;
  179.             }
  180.  
  181.             while(var24-- > 0) {
  182.                var6 = (InputStream)this.streams.elementAt(var24);
  183.  
  184.                try {
  185.                   var7 = var6.read(var2, 0, var1);
  186.                } catch (IOException var16) {
  187.                   var7 = -1;
  188.                }
  189.  
  190.                if (var7 <= 0) {
  191.                   this.streams.removeElementAt(var24);
  192.                   var7 = 0;
  193.  
  194.                   try {
  195.                      var6.close();
  196.                   } catch (IOException var15) {
  197.                   }
  198.                }
  199.  
  200.                while(var7-- > 0) {
  201.                   var23[var7] += var21[var2[var7] & 255];
  202.                }
  203.             }
  204.  
  205.             int[] var9 = ULAW_LUT;
  206.  
  207.             int var30;
  208.             for(int var28 = var1; var28-- > 0; var2[var28] = (byte)var30) {
  209.                var30 = var23[var28];
  210.                if (var30 >= 0) {
  211.                   if (var30 > 32635) {
  212.                      var30 = 32635;
  213.                   }
  214.  
  215.                   var30 += 132;
  216.                   int var11 = var9[var30 >> 7];
  217.                   int var12 = var30 >> var11 + 3 & 15;
  218.                   var30 = (var11 << 4 | var12) ^ 255;
  219.                } else {
  220.                   var30 = -var30;
  221.                   if (var30 > 32635) {
  222.                      var30 = 32635;
  223.                   }
  224.  
  225.                   var30 += 132;
  226.                   int var33 = var9[var30 >> 7];
  227.                   int var34 = var30 >> var33 + 3 & 15;
  228.                   var30 = (var33 << 4 | var34) ^ 127;
  229.                }
  230.             }
  231.  
  232.       }
  233.    }
  234.  
  235.    private synchronized boolean waitForData() throws InterruptedException {
  236.       Vector var1 = this.streams;
  237.       if (var1.elementCount != 0) {
  238.          return false;
  239.       } else {
  240.          if ((this.status() & 1) != 0) {
  241.             int var2 = this.getBufferDuration();
  242.             if (var2 != 0) {
  243.                Thread.currentThread();
  244.                Thread.sleep((long)var2);
  245.             }
  246.  
  247.             while((this.status() & 1) != 0) {
  248.                Thread.currentThread();
  249.                Thread.sleep(20L);
  250.             }
  251.          }
  252.  
  253.          this.flush();
  254.          int var3 = this.getBufferDuration();
  255.          if (var3 != 0) {
  256.             Thread.currentThread();
  257.             Thread.sleep((long)var3);
  258.          }
  259.  
  260.          while((this.status() & 1) != 0) {
  261.             Thread.currentThread();
  262.             Thread.sleep(20L);
  263.          }
  264.  
  265.          this.close();
  266.          this.wait(0L);
  267.          this.open();
  268.          return true;
  269.       }
  270.    }
  271.  
  272.    public void play() {
  273.       try {
  274.          while(this.dev > 0) {
  275.             this.waitForData();
  276.             this.mix();
  277.             this.audioWrite(this.ulaw, this.ulaw.length);
  278.             if ((this.status() & 2) == 0 && (this.status() & 1) != 0) {
  279.                int var1 = this.getBufferDuration();
  280.                if (var1 != 0) {
  281.                   Thread.currentThread();
  282.                   Thread.sleep((long)this.getBufferDuration());
  283.                }
  284.  
  285.                while((this.status() & 1) != 0) {
  286.                   Thread.currentThread();
  287.                   Thread.sleep(20L);
  288.                }
  289.             }
  290.          }
  291.  
  292.       } catch (InterruptedException var2) {
  293.       }
  294.    }
  295.  
  296.    public synchronized void closeStreams() {
  297.       Enumeration var1 = this.streams.elements();
  298.  
  299.       while(var1.hasMoreElements()) {
  300.          try {
  301.             ((InputStream)var1.nextElement()).close();
  302.          } catch (IOException var2) {
  303.          }
  304.       }
  305.  
  306.       this.streams = new Vector();
  307.    }
  308.  
  309.    public int openChannels() {
  310.       Vector var1 = this.streams;
  311.       return var1.elementCount;
  312.    }
  313. }
  314.